package com.gmall.data.functions;

import com.gmall.data.pojo.LogBean;
import org.apache.flink.api.java.functions.KeySelector;

/**
 * @author wufengchi
 * @create 2021-04-20 下午11:25
 */
public class DeviceKeySelector implements KeySelector<LogBean, String> {

    @Override
    public String getKey(LogBean logBean) throws Exception {
        return logBean.getDeviceId();
    }
}
